package hadoop.ch52.v17124080120;

import java.io.IOException;
import org.apache.hadoop.io.IntWritable;
import org.apache.hadoop.mapreduce.Reducer;

public class SalaryTotalReducer extends Reducer<IntWritable,Employee,IntWritable,Employee> {

    protected void reduce(IntWritable k3, Iterable<Employee> v3,
                          Context context) throws IOException, InterruptedException {
        for(Employee e:v3){
            context.write(k3,e);
        }
    }
}

